package com.xian.java.stream;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.LocalEnvironment;

public class StreamTest {
    public static void main(String[] args) {
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        LocalEnvironment localEnvironment = ExecutionEnvironment.createLocalEnvironment();


    }
}
